59507381c8c725e28b2978641e638b7c7931f4e9,src/com/comcast/cns/util/CNSWorkerStatWrapper.java,CNSWorkerStatWrapper,getCassandraWorkerStats,#,31

Before Change


	private static Logger logger = Logger.getLogger(CNSWorkerStatWrapper.class);
	
	public static List<CNSWorkerStats> getCassandraWorkerStats(){
		CassandraPersistence cassandraHandler = new CassandraPersistence(CMBProperties.getInstance().getCNSKeyspace());
		
		List<Row<String, String, String>> rows = cassandraHandler.readNextNNonEmptyRows("CNSWorkers", null, 1000, 10, new StringSerializer(), new StringSerializer(), new StringSerializer(), CMBProperties.getInstance().getReadConsistencyLevel());
		List<CNSWorkerStats> statsList = new ArrayList<CNSWorkerStats>();

After Change


	private static Logger logger = Logger.getLogger(CNSWorkerStatWrapper.class);
	
	public static List<CNSWorkerStats> getCassandraWorkerStats(){
		AbstractCassandraPersistence cassandraHandler = CassandraPersistenceFactory.getInstance(CMBProperties.getInstance().getCNSKeyspace());
		
		List<Row<String, String, String>> rows = cassandraHandler.readNextNNonEmptyRows("CNSWorkers", null, 1000, 10, new StringSerializer(), new StringSerializer(), new StringSerializer(), CMBProperties.getInstance().getReadConsistencyLevel());
		List<CNSWorkerStats> statsList = new ArrayList<CNSWorkerStats>();